package io.adrainty.bolee.task.stream;

import io.adrainty.bolee.framework.mq.basic.MQMessage;
import io.adrainty.bolee.framework.mq.basic.MQMessageType;
import io.adrainty.bolee.framework.mq.stream.BaseStreamHandler;
import org.springframework.stereotype.Component;

/**
 * <p>LogMsgConsumer</p>
 *
 * @author AdRainty
 * @version V1.0.0
 * @description LogMsgConsumer
 * @since 2025/7/30 13:51:49
 */

@Component(value = "logChannel")
public class LogMsgConsumer extends BaseStreamHandler {

    @Override
    public void doConsume(MQMessage message) {

    }

    @Override
    public MQMessageType acceptMsgType() {
        return MQMessageType.LOG_MESSAGE;
    }

}
